import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('81.71.137.167'))
channel = connection.channel()

# 声明一个队列（创建一个队列）
channel.queue_declare(queue='s13q1', durable=True)

def callback(ch, method, properties, body):
    print(body)
    # 如果下面auto_ack=False,就代表着接收到body后要手动去回复服务端, 如果为Ture的话下面这行就不需要写了
    ch.basic_ack(delivery_tag=method.delivery_tag)

# 加了下面这行代表消费者不再轮流消费了, 而是改成谁闲置谁来消费
channel.basic_qos(prefetch_count=1)

channel.basic_consume('s13q1', callback, auto_ack=False)

channel.start_consuming()